package com.acoreful.acf2admin.commons.mq;

import org.apache.thrift.TBase;

/**
 *	生产者
 */
public interface MqProducer {

	/**
	 * 发送
	 * @param exchange	交换区
	 * @param routingKey	交换区对应队列key
	 * @param message
	 */
	void send(String exchange, String routingKey, TBase<?, ?> message);
	
}
